package com.oig.sys.msg.app;

import com.oig.sys.msg.dto.MqMsgDto;
import com.oig.sys.msg.entity.TbMqMsg;
import com.oig.sys.msg.vo.MqMsgVo;

import java.util.List;

public interface IAppMqMsgService {

    /**
     * add
     */
    MqMsgVo addMqMsg(MqMsgDto mqMsgDto);

    TbMqMsg getMqMsg(Integer id);

    List<TbMqMsg> findAllUnReadyMsg();
    List<TbMqMsg> findAllUnSendMqMsg();

    void updateMsgError(TbMqMsg mqMsg);

    void updateMsgReady(TbMqMsg mqMsg);

    void moveMsgToHis(TbMqMsg mqMsg);

}
